package com.xbongbong.pro.rabbitmq.binders;

import com.xbongbong.pro.rabbitmq.constant.CostRecalculationConstant;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Service;

/**
 * 成本重算 消息队列
 * @author jiping.yang
 * @date 2021/12/2 10:14
 */
@Service("costRecalculationConsumerBinder")
public interface CostRecalculationConsumerBinder {
    /**
     * 成本重算 消息队列
     */
    @Input(CostRecalculationConstant.COST_RECALCULATION_INPUT)
    SubscribableChannel costRecalculationInput();

}
